3f6cd467362761195353164484ba3551c23d6cd5,modules/elasticsearch/src/main/java/org/elasticsearch/transport/netty/NettyTransport.java,NettyTransport,doStart,#,168
Before Change
@Override protected void doStart() throws ElasticSearchException {
clientBootstrap = new ClientBootstrap(new NioClientSocketChannelFactory(
Executors.newCachedThreadPool(daemonThreadFactory(settings, "transportClientBoss")),
Executors.newCachedThreadPool(daemonThreadFactory(settings, "transportClientIoWorker")),
workerCount));
ChannelPipelineFactory clientPipelineFactory = new ChannelPipelineFactory() {
After Change
}
serverOpenChannels = new OpenChannelsHandler();
if (blockingServer) {
serverBootstrap = new ServerBootstrap(new OioServerSocketChannelFactory(
Executors.newCachedThreadPool(daemonThreadFactory(settings, "transport_server_boss")),
Executors.newCachedThreadPool(daemonThreadFactory(settings, "transport_server_worker"))
));
} else {
serverBootstrap = new ServerBootstrap(new NioServerSocketChannelFactory(
Executors.newCachedThreadPool(daemonThreadFactory(settings, "transport_server_boss")),
Executors.newCachedThreadPool(daemonThreadFactory(settings, "transport_server_worker")),
workerCount));
}